package com.jeffse.light.stream.core.function.advance;

import com.jeffse.light.stream.core.data.collector.Collector;
import com.jeffse.light.stream.core.data.context.ProcessContext;
import com.jeffse.light.stream.core.pojo.window.WindowInfo;
import com.jeffse.light.stream.core.function.base.Function;

import java.io.Serializable;
import java.util.List;

public interface WindowFunction<T, O> extends Function, Serializable {
    public void window(List<T> list, ProcessContext<O> ctx) throws Exception;
}
